package com.shop.user.mqHandler.error;

import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.annotation.*;
import org.springframework.stereotype.Component;

/**
 * @author 'banxia'
 * @version 1.0
 * @description TODO
 * @date 2023/2/28 18:06
 */
@Component
@Slf4j
public class OrderCancelError {


/*    @RabbitListener(bindings = @QueueBinding(
            value = @Queue(name = "error.queue",durable = "true"),
            exchange = @Exchange(name = "error.direct"),
            key = "error"
    ))*/
    @RabbitListener(queues = "error.queue")
    public void errorHandle(String msg){
        log.error("================================================");
        log.error("消息删除失败，msg:{}",msg);
        log.error("================================================");
    }

}
